2dff97a51ed01c7fcbeb21a04a8292aa66e9098e,framework/service/src/org/ofbiz/service/test/ServiceEngineTestServices.java,ServiceEngineTestServices,testServiceDeadLockRetry,#DispatchContext#Map#,38
Before Change
GenericResultWaiter threadAWaiter = dispatcher.runAsyncWait("testServiceDeadLockRetryThreadA", null, false);
GenericResultWaiter threadBWaiter = dispatcher.runAsyncWait("testServiceDeadLockRetryThreadB", null, false);
// make sure to wait for these to both finish to make sure results aren't checked until they are done
threadAWaiter.waitForResult();
threadBWaiter.waitForResult();
} catch (Exception e) {
String errMsg = "Error running deadlock test services: " + e.toString();
After Change
GenericResultWaiter threadAWaiter = dispatcher.runAsyncWait("testServiceDeadLockRetryThreadA", null, false);
GenericResultWaiter threadBWaiter = dispatcher.runAsyncWait("testServiceDeadLockRetryThreadB", null, false);
// make sure to wait for these to both finish to make sure results aren't checked until they are done
Map threadAResult = threadAWaiter.waitForResult();
Map threadBResult = threadBWaiter.waitForResult();
List errorList = FastList.newInstance();
if (ServiceUtil.isError(threadAResult)) {
errorList.add("Error running testServiceDeadLockRetryThreadA: " + ServiceUtil.getErrorMessage(threadAResult));
}
if (ServiceUtil.isError(threadBResult)) {
errorList.add("Error running testServiceDeadLockRetryThreadB: " + ServiceUtil.getErrorMessage(threadBResult));